﻿using KafkaUtil.Integration;
using System;

namespace KafkaUtil.Interface
{
    public interface IClientProducer : IDisposable
    {
        /// <summary>
        /// 发送消息
        /// </summary>
        /// <param name="kafkaMessages"></param>
        /// <param name="callback"></param>
        void Publish(KafkaMessage[] kafkaMessages, Action<DeliveryResult> callback = null);
    }
}
